package command

import (
	"context"

	corev1 "k8s.io/api/core/v1"
)

type Commander interface {
	Start(ctx context.Context)
}

var (
	StartCMD              = "start"
	StopCMD               = "stop"
	PodChannel            = make(chan *corev1.Pod)
	DataflowConfigChannel = make(chan *corev1.ConfigMap)
)
